package common.mq.receiver.service;

import common.mq.basic.service.MessageService;
import common.mq.basic.service.QueueService;
import common.mq.master.service.IMasterService;
import common.mq.receiver.po.SendResult;
import common.mq.receiver.thrift.TMessageInfo;
import common.mq.register.service.IRegisterService;

public interface IReceiveService {
	
	public void setRemoveDuplicateService(
			IRemoveDuplicateService removeDuplicateService);

	public void setMasterService(IMasterService masterService);

	public void setRegisterService(IRegisterService registerService);

	public void setMessageService(MessageService messageService);

	public void setQueueService(QueueService queueService);

	public SendResult receiveMessage(TMessageInfo msgInfo);
}
